package com.wangbloc.domain.service;

import org.eclipse.paho.client.mqttv3.MqttClient;

/**
 * @author wangbloc
 * @version 1.0
 * @date 2023/2/9 22:38
 **/
public interface MqttService {

    /**
     * 获取默认客户端
     *
     * @return {@link MqttClient}
     */
    MqttClient getDefaultClient();

    /**
     * 自定义订阅
     *
     * @param topic 主题
     */
    void customSubscribe(String topic);

    /**
     * 自动订阅
     */
    void lostAutoSubscribe();

}
